package dmp.tags

import org.apache.spark.sql.Row

/**
  * author:CN.CDG
  * Date:2019/2/16
  * Time:11:39
  * 设备标签
  **/
object DiviceTags extends Tags {
  override def mkTags(args: Any*): List[(String, Int)] = {
    //声明List集合
    var list=List[(String,Int)]()
    //解析参数
    val row: Row = args(0).asInstanceOf[Row]
    //获取设备类型client
    val cient = row.getAs[Int]("client")
    if(cient==1) list:+=("D00010001",1)
    else if(cient==2) list:+=("D00010002",1)
    else if(cient==3) list:+=("D00010003",1)
    else list:+=("D00010004",1)


//联网方式标签
    //获取networkmannername
    val netName = row.getAs[String]("networkmannername")
    if(netName.equals("WIFI")) list:+=("D00020001",1)
    else if(netName.equals("4G")) list:+=("D00020002",1)
    else if(netName.equals("3G")) list:+=("D00020003",1)
    else if(netName.equals("2G")) list:+=("D00020004",1)
    else list:+=("D00020005",1)

//运营商标签
    //获取ispname
    val str = row.getAs[String]("ispname")
    if (str.equals("移动")) list:+=("D00030001",1)
    else if (str.equals("联通")) list:+=("D00030002",1)
    else if (str.equals("电信")) list:+=("D00030003",1)
    else  list:+=("D00030004",1)
    list
  }
}
